package com.cjq.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Service;

/**
 * @author junqiancai@foxmail.com
 * @since 2021/6/22 0:53
 */

@Service
//消费者
public class Consumer {
//    @Autowired
//    private JmsMessagingTemplate jmsMessagingTemplate;
//
//    // 使用JmsListener配置消费者监听的队列，其中name是接收到的消息
//    @JmsListener(destination = "ActiveMQQueue")
//    // SendTo 会将此方法返回的数据, 写入到 OutQueue 中去.
//    @SendTo("SQueue")
//    public String handleMessage(String name) {
//        System.out.println("成功接受Name" + name);
//        return "成功接受Name" + name;
//    }
//
//    //接收queue类型消息
//    //destination对应配置类中ActiveMQQueue("springboot.queue")设置的名字
//    @JmsListener(destination="springboot.queue")
//    public void ListenQueue(String msg){
//        System.out.println("接收到queue消息：" + msg);
//    }
//
//    //接收topic类型消息
//    //destination对应配置类中ActiveMQTopic("springboot.topic")设置的名字
//    //containerFactory对应配置类中注册JmsListenerContainerFactory的bean名称
//    @JmsListener(destination="springboot.topic", containerFactory = "jmsTopicListenerContainerFactory")
//    public void ListenTopic(String msg){
//        System.out.println("接收到topic消息：" + msg);
//    }
}